package com.rocketmq.consumer.service.impl;

import com.alibaba.fastjson.JSON;
import com.google.common.base.Objects;
import com.rocketmq.consumer.model.MseeageEntity;
import com.rocketmq.consumer.service.ConsumerTest;
import com.rocketmq.consumer.utils.StatisticCount;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

/**
 * @Description:
 * @author: zhengfei
 * @param:
 * @date: 2018-06-22 下午6:31
 */

@Service
@Slf4j
public class ConsumerTestImpl implements ConsumerTest {


    @Override
    public void process(String body, String type) {
        MseeageEntity entity = JSON.parseObject(body, MseeageEntity.class);
        if (Objects.equal(entity, null)) {
            return;
        }
        //log.info(":{} - > {}", type, entity.getId());
    }


}
